package com.tensai.study.新概念.响应式编程.reactor.flux;

import org.junit.Test;
import reactor.core.publisher.Flux;

import java.util.HashSet;
import java.util.Set;

/**
 * @author Tensai
 */
public class FromIterableTest {

    @Test
    public void test() {
        Set<String> v = new HashSet<>();
        v.add("1");
        v.add("2");
        v.add("3");
        Flux.fromIterable(v).subscribe(System.out::println);
    }
}
